package com.dqlp.yf.rabbitmq.constant;

/**
 * @program: rabbitmq
 * @description: rabbitmq常量
 * @author: andy
 * @create: 2019-09-07 10:55
 */
public class MqConstant {
    public final static String TEST_QUEUE = "test_queue";
    public final static String TEST_EXCHANGE = "test_exchange";
    public final static String ROUTERKEY = "test_queue";


    public final static String DIRECT_QUEUE = "direct_queue";
    public final static String DIRECT_EXCHANGE = "direct_exchange";
    public final static String DIRECT_ROUTERKEY = "direct_routerKey";

    //死信队列  出现的情况有三种：1过期的消息，2设置队列里面达到了最大值，新增的消息会进入死信队列，
    // 3拒绝的消息，比如：手动ack的时候调用nack并且不重回队列
    public final static String DLX_EXCHANGE = "dlx_exchange";
    public final static String DLX_QUEUE = "dlx_queue";
    public final static String DLX_ROUTERKRY = "dlx_routerkey";


    //topic 模式
    public final static String TOPIC_EXCHANGE = "topic_exchange";
    public final static String TOPIC_QUEUE = "topic_queue";
    public final static String TPOIC_ROUTERKEY = "topic.#";

    //fanout 模式
    public final static String FANOUT_EXCHANGE = "fanout_exchange";
    public final static String FANOUT_QUEUE = "fanout_queue";


    //延迟队列
    public static final Integer delay = 10000;
    public static final String LAZY_EXCHANGE = "Lazy_Exchange";
    public static final String LAZY_QUEUE = "Lazy_Queue";
    public static final String LAZY_KEY = "lazy.#";


 }

